package com.teaphy.coroutinecrawler.flow.operators.filter

import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.flow.drop
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.runBlocking

fun main() = runBlocking {
    flow {
        for(value in 0..8) {
            emit(value)
        }
    }.drop(5)
        .collect {
            println("接收到的数据：$it")
        }

    println("Done")
}